package com.yln.watcher.client;

import java.util.List;
import java.util.Optional;

public interface ZkContext {
    void cacheWorkers(List<String> allWorkers);
    void cacheTasks(List<String> tasks);
    List<String> getHasProceededTasks();
    void taskProcessing(String task);
    void addNotAssignedTasks(List<String> taskNodes);
    Optional<String> randomWorker();
    List<String> getAllWorkers();
    List<String> getAllTasks();
    void removeTask(String task);

}
